16e6ed9ebcf3568121ca95d569bbd11ae8963e60,src/main/java/com/deutscheboerse/risk/dave/MongoDBPersistenceVerticle.java,MongoDBPersistenceVerticle,startStoreHandlers,#Handler#,128

Before Change


        // TODO: Use JsonObjects for risk limits and move it to store(message) method as well
        eb.consumer("ers.RiskLimit", message -> storeRiskLimit(message));

        completer.handle(Future.succeededFuture());
    }

    private void startQueryHandlers(Handler<AsyncResult<Void>> completer)

After Change


        eb.consumer("ers.RiskLimit", message -> storeRiskLimit(message));

        LOG.info("Event bus store handlers subscribed");
        return Future.succeededFuture();
    }

    private Future<Void> startQueryHandlers(Void unused)